# -- coding: utf-8 --
from celery import Celery

# coding:utf-8

# from apps.apis.user_api import SendMessageApi
from tasks.main import app_celery
import time

# #创建celery对象
# app=Celery("ihome",broker="redis://127.0.0.1:6379/5")

# 定义任务
@app_celery.task
def add(x,y):
    time.sleep(10)
    return str(x + y)